package com.xebest.web.service.impl;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

import com.xebest.api.dto.SendMessageDTO;
import com.xebest.web.service.ReceiveOrderService;

@EnableBinding(ReceiveOrderService.class)
public class TestOrderReceiveServiceImpl {
	
	@StreamListener(ReceiveOrderService.SEND_ORDER)
	public void receive(SendMessageDTO entity){
		System.out.println("接受消息内容为"+entity.getSpanId()+"--------"+entity.getOrderId());
	}
}
